fe3d21427c475580f79dbcf4359629ffbccccd6f,kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ReplicaSetOperationsImpl.java,ReplicaSetOperationsImpl,waitUntilReady,#number#TimeUnit#,256
Before Change
return rs;
}
final CountDownLatch latch = new CountDownLatch(1);
Watcher<ReplicaSet> watcher = new ReadinessWatcher<>(latch);
try (Watch watch = watch(watcher)) {
if (latch.await(amount, timeUnit)) {
return get();
}
}
throw new KubernetesClientTimeoutException(rs.getKind(), getName(), getNamespace(), amount, timeUnit);
}
private static class ReplicaSetReaper implements Reaper {
After Change
return rs;
}
ReadinessWatcher<ReplicaSet> watcher = new ReadinessWatcher<>(rs.getKind(), getName(), getNamespace());
try (Watch watch = watch(watcher)) {
return watcher.await(amount, timeUnit);
}
}